package com.ehotting.mqbd.core.mq.consumer.action;

import com.ehotting.mqbd.api.bean.MQDataAble;
import com.ehotting.mqbd.api.bean.MqApplicationContext;
import com.ehotting.mqbd.api.enums.DirectionEnum;
import com.ehotting.mqbd.api.enums.TopicEnum;
import org.apache.rocketmq.client.consumer.listener.MessageListener;
import org.apache.rocketmq.common.message.MessageExt;

public interface ConsumerActionAble {
    public String getModule();
    public void invoke(MessageExt msg) throws Exception;
    public String getHost();
    public DirectionEnum getDirection();
    public TopicEnum getTopic();
    public String getSolverIp();
    public void extInvoke(MQDataAble data);
    public MessageListener getMessageListener();
    public MqApplicationContext getMqApplicationContext();
}